package com.mojo.web.kafka;

import org.springframework.cloud.stream.annotation.Output;
import org.springframework.messaging.MessageChannel;

/**
 * Kafka消息源
 *
 * @author <a href="mailto:sjj@jianzhimao.com">mojo</a>
 * copyright (C), 2013-2022, 广州九尾信息科技有限公司
 * @date 2022/2/26 15:30
 */
public interface MySource {
    //自定义source
//定义获取messageChannel接口方法
    @Output("myoutput")
    MessageChannel myChannel();
}
